from kombu import Queue
BROKER_URL = 'redis://localhost:6379/1'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/2'

# 导入任务
CELERY_IMPORTS = (
    'project02.apps.to_mysql_task',
)


# 配置队列及交换机

# TODO 交换器：topic
"""
task1 执行task1任务
task2 执行task1、task2任务
task3 执行task3任务
"""
CELERY_QUEUES = (
    Queue('task', routing_key='task'),
)

CELERY_ROUTES = {
    'project02.apps.to_mysql_task.task_to_sql': {'queue': 'task', 'routing_key': 'task'},
}


# TODO 定时任务
# CELERYBEAT_SCHEDULE = {
#     'task4': {
#         'task': 'day06.apps.tasks.task4',
#         'schedule': timedelta(seconds=10),  # TODO 间隔10秒执行一次任务
#         'args': (666, 2),
#         'options': {
#             'queue': 'task4',
#             'routing_key': 'task4'
#         }
#     }
# }
